package com.tienon.message.Test;

import javax.annotation.Resource;

import org.junit.Test;

import com.tienon.message.service.MQSendMsgService;

public class MQSendMsgServiceTest extends UnitTestEnv {

	@Resource
	private MQSendMsgService service;
	/**
	 * 	db get 100 connect 30
	 *  thread 20
	 *  27455 
	 *  271
	 *  :101
	 *  
	 *  
	 *  db get 50 connect 100
	 *  thread 50
	 *  27455
	 *  219
	 *  :125
	 *  
	 *  close log
	 *  27455
	 *  207
	 *  :132 ~~ 133
	 */
	@Test
	public void TestMQSendService() {
		
		service.startSendAppMsgToMQ();
		while (true) {
			// 让主程序不结束
		}
	}

}
